package cas.ihep.spark.util;

import java.io.Serializable;

public interface IterationClientListener<RDD,T,R> extends Serializable {
    void initialize(NamedResourceManager manager,RDD rdd);
    R iterate(NamedResourceManager manager,RDD rdd,T t);
    void cleanup(NamedResourceManager manager,RDD rdd);
}
